package cn.jr.dao.impl;

import cn.jr.dao.IUserAndMoneyDao;
import cn.jr.pojo.ShopRunAndMoney;
import cn.jr.util.DBHelper;

import java.util.ArrayList;

public class UserAndMoneyDaoImpl implements IUserAndMoneyDao {
    DBHelper db = new DBHelper();
    @Override
    public int updateUserAndMoney(String AccountId, Double AccountMoney) {
        /**
         * 更新用户余额
         * @param AccountId 用户编号
         * @param AccountMoney 用户余额
         * @return 影响行数

         */
        String sql="update account set AccountMoney=AccountMoney+? where AccountId=?";
        return db.dtUpdate(sql,AccountMoney,AccountId);
    }

    @Override
    public int insertAccount(String AccountId) {
        /**
         * 新增用户账户
         * @param AccountId 用户编号
         * @return 影响行数
         */
        String sql="insert into account(AccountId,AccountMoney) values(?,0)";
        return db.dtUpdate(sql,AccountId);
    }

    @Override
    public ArrayList<ShopRunAndMoney> selectAccountMoney() {
        /**
         * 查询所有用户账户
         * @return 用户账户集合
         */
        String sql="select * from account";
        return db.dtQuery(sql,ShopRunAndMoney.class);
    }
}
